package com.youshang520i.consuldiscoveryprovider.service;

import com.youshang520i.consuldiscoveryprovider.model.Mail;

public interface RocketmqService {

    /**
     * 接受MQ消息
     * @param str
     * @return
     */
    Mail receive(String str);

    /**
     * 广播模式测试
     */
    Mail broadcast1(String str);
    Mail broadcast2(String str);
    Mail broadcast3(String str);
    Mail broadcast4(String str);
}
